草庐IT

Java TCP 连接

全部标签

java - 将 node.js 进程与 java/scala 代码连接起来的最快方法

我有一个用java/scala实现的计算库。我也有一些node.js代码为我的应用程序服务。我需要找到一种方法,如何以最高性能连接这两个世界,同时还要考虑简单性。我正在考虑通过共享内存进行进程间通信,但在node.js中找不到任何成熟的方法来做到这一点这应该主要用作从node.js代码调用一些java(最好是任何)代码的代理机制。从node.js到java端,它只会请求元数据传递,但是从java到node.js有时可能会返回大量数据(假设100-200kb作为上边界,90%的数据中大约有600-1000字节)案例)但是,请求的数量可能很大。认为OpenMP可能是一个选项,但也找不到任何

连接到公共(public) ip 地址的 Java 套接字

我需要制作一个服务器和连接到服务器的客户端。问题:“服务器正常工作。客户端只能连接到本地主机,无法连接到互联网上的服务器。我希望客户端通过公共(public)ip连接到服务器-服务器所在的地址。”首先,我已确保端口已转发且可访问,我已经测试了该端口,其次我已从服务器计算机完全禁用防火墙。下面是我使用的测试代码:服务器:没什么特别的,只是简单-如果客户端已连接则终止,否则只是等待连接。publicclassServer{publicstaticvoidmain(Stringargs[]){try{ServerSocketsrvr=newServerSocket(52000);srvr.a

java - Kafka 客户端连接池

执行kafka客户端的生产者/消费者连接池是否有意义?kafka是否在内部维护一个已初始化并准备好使用的连接对象列表?我们希望最大限度地减少连接创建时间,以便在发送/接收消息时没有额外的开销。目前我们正在使用apachecommons-pool库GenericObjectPool来保持连接。任何帮助将不胜感激。 最佳答案 Kafka客户端维护自己与集群的连接。生产者和消费者都保持与他们正在交互的代理的连接。如果他们停止交互,在connections.max.idle.ms之后连接将被关闭。此设置也存在于代理上,因此您可能需要与您的管

java - 如何使用 Apache Camel Netty4 在异步模式下通过已建立的 TCP 连接发回响应?

我在消费者模式下使用Netty4组件(http://camel.apache.org/netty4.html)构建一个具有ApacheCamel路由的微服务。因此,在我的微服务中,我正在构建的这条路由将通过TCP连接接收消息。为此,我这样做了:@Overridepublicvoidconfigure()throwsException{this.from("netty4:tcp://localhost:7000?textline=true&encoding=utf8").process(newProcessor(){@Overridepublicvoidprocess(finalExch

java - 检测 Web 服务中的客户端断开连接

我正在使用ApacheCXFWeb服务堆栈。当客户端在操作完成之前超时或与服务器断开连接时,服务器将继续运行该操作直到完成。我想让服务器检测客户端何时断开连接并相应地进行处理。有没有一种方法可以检测客户端何时使用ApacheCXF断开连接?使用其他Java网络服务堆栈怎么样? 最佳答案 我不熟悉ApacheCXF,但以下内容应该适用于任何基于JavaServlet的框架。为了确定用户是否已断开连接(停止按钮、关闭浏览器等),服务器必须尝试发送数据包。如果TCP/IP连接已关闭,将抛出IOException。理论上,Java应用程序可

Java:有人知道检测互联网连接质量的库吗?

我知道一个简单的URLConnection到google可以检测我是否连接到internet,毕竟我相信internet一切都很好,如果我不能连接到google。但此时我正在寻找的是一个库,它可以衡量我的互联网连接在BOTH响应能力和可用带宽方面的有效性。但是,我不想测量有多少带宽可能可用,因为这太占用资源了。我真的只需要能够测试我是否可以在Y时间内收到类似XkB的内容。这样的库是否已经存在? 最佳答案 这个还真不好判断。在当今下载速度为20多Mb/s的ADSL2+世界中,您在很大程度上取决于您上游的一切速度。因此,例如,如果您要连

java - Hibernate:这个映射到外键连接的子类有什么问题?

我正在尝试使用Hibernate来获得经验。我创建了一个包含两个子类的类Person:Student和Worker:publicabstractclassPerson{privateLongid;...}publicclassStudentextendsPerson{...}另一个类Employer与Worker具有双向一对多关系。publicclassWorkerextendsPerson{privateEmployeremployer;...}publicclassEmployer{privateStringtaxId;privateSetemployees=newHashSet(

java - 如何获得图中某些节点彼此断开连接的最小成本

在给定的图中,我想计算在图中将某些节点彼此断开连接的最小成本。示例:在此图中,假设我想通过删除这些节点之间的一些边来断开nodeA、nodeC和nodeF之间的连接。即通过删除edgeA-B和edgeF-E,节点A、C和F将断开连接。这里的成本是指被删除的边的长度。在此示例中,将NodeA、NodeC和NodeF彼此断开的总最小成本为2+1=3。有人可以提供一些提示吗?我无法对这个问题进行归类,这是一种最短路径问题还是最小生成树问题? 最佳答案 这称为多端切割问题。不幸的是,似乎没有维基百科条目。问题是,给定一个加权图和称为term

java - 运行 Nutch 2 时出现连接拒绝错误

我试图在我的系统上运行Nutch2爬虫,但出现以下错误:Exceptioninthread"main"org.apache.gora.util.GoraException:java.io.IOException:java.sql.SQLTransientConnectionException:java.net.ConnectException:Connectionrefusedatorg.apache.gora.store.DataStoreFactory.createDataStore(DataStoreFactory.java:167)atorg.apache.gora.store

java - 在 Java 中,为什么 readLine() 会阻塞已关闭的套接字连接?

我有一个简单的客户端/服务器应用程序。服务器设置为如果在N秒内没有数据进入,则会发生超时并关闭套接字连接。我通过Socket.setSoTimeout()执行此操作。如果客户端挂起,一切正常。但是,如果客户端死了(例如,我用Ctrl-C杀死它),那么readLine()永远不会超时。这是服务器代码,如果有区别的话:publicvoidrun(){PrintWriterout=null;BufferedReaderin=null;try{sock.setSoTimeout(10000);out=newPrintWriter(sock.getOutputStream(),true);in=